package com.deep.stream.delay.delaycomponent;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Service;

/**
 * Description
 *
 * @author deeprado
 */
@Service
public interface DelayInputConsumer {
    @Input("delayTestInput")
    SubscribableChannel delayInput();
}
